package com.yifeng.repo.flink.data.transport.streaming.functions.api;

import java.io.Closeable;

import org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext;

import com.yifeng.repo.flink.data.transport.dto.DataPacket;

public interface Engine extends Closeable {
	
	/**
	 * 异步方法
	 */
	public void run(SourceContext<DataPacket> ctx);
	
	/**
	 * 同步方法
	 */
	public void execute(SourceContext<DataPacket> ctx);

}
